package module

import "worm/item"

type Pipeline interface {
	Module
	//条目处理管道使用的条目处理函数列表
	ItemProcessors() []ProcessItem
	//向管道发送条目
	Send(item.Item) []error
	//捕获条目的处理函数是否有报错
	FailFast() bool
	//设置是否捕获失败
	SetFailFast(bool)
}

type ProcessItem func(item item.Item) (item.Item, error)
